package com.gaofei;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.kafka.core.KafkaTemplate;

//@SpringBootTest
//public class MyProducer {
//
//    @Autowired
//    //                  1.主题的类型,2.消息的类型
//    private KafkaTemplate<String,String> kafkaTemplate;
//
//
//    @Test
//    public void testSend(){
//        kafkaTemplate.send("2102A","","你好,我是quick start");
//    }
//}
